package org.rency.mq.kafka.core;

/**
 * ${todo}
 *
 * @author: Created by user_rcy@163.com on 2016/10/26.
 * @version: V1.0.0
 * @since JDK 1.8
 */
public interface KafkaConstant {

    public static final long DEFAULT_CONSUMER_POLL_TIMEOUT = 1000;

    public static final int DEFAULT_CONSUMER_CONTAINER_POOL_CONCURRENCY = 1;

    /**
     * 事件发布失败自动重试次数
     */
    public static final int DEFAULT_AUTO_RETRY_TIMES = 3;

    public static final String DEFAULT_FAILED_TOPIC_NAME = "org.rency.kafka.auto.failed.topic";
}
